from pandas import DataFrame
from sqlalchemy import create_engine, text
import pandas as pd

from examples.plugin.common import timer


@timer
def run(param_dict: dict) -> DataFrame:
    path = param_dict["path"]
    df = pd.read_parquet(path) # parquet读取
    return df
